'''
Created on 2020年3月4日

@author: yinfs
'''
import sqlite3

class DBAccess(object):
    '''
    classdocs
    '''


    def __init__(self):
        '''
                    数据库连接初始化函数，创建数据库的连接
        '''
        self.connection = sqlite3.connect('pcs.db')
        self.conn = self.connection.cursor()
        
    def execute_update(self, sql, ob):
        '''
                    数据库的插入、修改函数
        :param sql: 传入的SQL语句
        :param ob: 传入数据
        :return: 返回操作数据库状态
        '''
        try:
            self.conn.executemany(sql, ob)
        except Exception as e:
            print('错误类型： ', e)
            return False
        finally:
            self.connection.commit()
        return True
        
    def execute_delete(self, sql, ob):
        '''
                    数据库的删除函数
        :param sql: 传入的SQL语句
        :param ob: 传入数据
        :return: 返回操作数据库状态
        '''
        try:
            self.conn.execute(sql, ob)
        except Exception as e:
            print('错误类型： ', e)
            return False
        finally:
            self.connection.commit()
        return True
     
    def execute_create(self, sql):
        '''
                    数据库的创建表函数
        :param sql: 传入的SQL语句
        :return: 返回操作数据库状态
        '''
        try:
            self.conn.execute(sql)
        except Exception as e:
            print('错误类型： ', e)
            return False
        finally:
            self.connection.commit()
        return True
        
    def execute_query(self, sql, ob):
        '''
                    数据库的查询函数
        :param sql: 传入的SQL语句
        :param ob: 传入数据
        :return: 返回操作数据库状态
        '''
        que = self.conn.execute(sql, ob)
        return que
    
    def close(self):
        '''
                    关闭数据库连接
        :return: 返回操作数据库状态
        '''
        self.conn.close()
        self.connection.close()
        
            
        
        